package main.test.SparkAPI.Baics.datasource

import org.apache.spark.sql.SparkSession

object HiveTable {
  val spark = SparkSession
    .builder()
    .appName("Spark Hive Example")

    .enableHiveSupport()
    .getOrCreate()
  import spark.implicits._
  import spark.sql

  def main(args: Array[String]): Unit = {

    sql(
      """
        |show databases
        |""".stripMargin).show(false)
//    sql(
//      """
//        |use lmqredo
//        |
//        |""".stripMargin)
//    sql("""show tables""").show(false)
    sql(
      """
        |select * from lmqredo.actor_freqs limit 10
        |""".stripMargin).show(false)

    val frame = spark.table("lmqredo.actor_freqs")
    frame.show(30,false)
    spark.stop()

  }

}
